# coding: utf-8
"""
@python version : python3.10
@file name      : my_celery.py
@date           : 2024/4/18 16:25
@author         : ziyang.yang@aliyun.com
@gitee          : https://gitee.com/ziyangyang1318
@blog           : www.yangziyang.top
@describe       : 
"""
import os

from celery import Celery

# 设置默认的Django配置模块，用于'celery'程序。
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'django_celery.settings')
# 初始化Celery应用实例。
app = Celery('django_celery')

# 通过字符串配置，避免worker进程间序列化配置对象。
# 设置命名空间为'CELERY'，意味着所有celery相关的配置键都应以'CELERY_'为前缀。
# app.config_from_object('django.conf:settings', namespace='CELERY')
app.config_from_object('django.conf:settings')

# 自动发现并加载所有注册的Django应用的任务模块。
app.autodiscover_tasks()


